package it.learn.kafka.consumer91.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class Test01Service {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    // @KafkaListener(id = "wxf-consumer91-01", topics = "topic1")
    // public void helloTest1(String message) {
    //     System.out.println("收到的消息 message = " + message);
    // }

    public void test02() {
        // kafkaTemplate.getProducerFactory()
    }

}
